7e1adb4976470b48a361ec6dcca7cbbcdb86d85f,src/java/org/apache/cassandra/net/ResponseVerbHandler.java,ResponseVerbHandler,doVerb,#MessageIn#number#,32
Before Change
Tracing.trace("Processing response from {}", message.from);
IAsyncCallback cb = callbackInfo.callback;
MessagingService.instance().maybeAddLatency(cb, message.from, latency);
cb.response(message);
}
}
After Change
{
//TODO: Should we add latency only in success cases?
MessagingService.instance().maybeAddLatency(cb, message.from, latency);
cb.response(message);
}
}
}